//package com.ruoyi.system.mq;
//
//import com.ruoyi.common.core.web.controller.BaseController;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.cloud.stream.messaging.Sink;
//
//@EnableBinding(Sink.class)
//public class MessageConsumer extends BaseController {
//
//    @StreamListener(Sink.INPUT)
//    public void handleMessage(String message) {
//        System.out.println("Received message: " + message);
//        // 处理消息的业务逻辑
//    }
//}
